<?php


namespace app\http;


use think\worker\Server;
use think\facade\Session;

class Worker extends Server{

    protected $socket = 'websocket://121.4.214.174:2345';//0.0.0.0
    public function __construct()
    {
        parent::__construct();
        $this->onMessage();
        // 或者这样调用
        $this->worker->onWorkerStart = function($worker)
        {
            echo "Worker starting...\n";
        };
    }
    /**
     * 收到信息
     * @param $connection
     * @param $data
     */
    public function onMessage()
    {
        $this->worker->onMessage = function($connection, $data)
        {
            dump($data);
            $connection->send($data);
        };
    }


//    public function onMessage($connection, $data)
//    {
//        $connection->send("收到啦！！！！！");
//    }

    /**
     * 当连接建立时触发的回调函数
     * @param $connection
     */
    public function onConnect($connection)
    {
        $connection->send("连接成功");
    }

    /**
     * 当连接断开时触发的回调函数
     * @param $connection
     */
    public function onClose($connection)
    {

    }

    /**
     * 当客户端的连接上发生错误时触发
     * @param $connection
     * @param $code
     * @param $msg
     */
    public function onError($connection, $code, $msg)
    {
        echo "error $code $msg\n";
    }

    /**
     * 每个进程启动
     * @param $worker
     */
    public function onWorkerStart($worker)
    {

    }

}
